package com.raymond.client.connector;

import io.netty.channel.*;

/**
 * 简单的mq连接控制器
 *
 * @author :  raymond
 * @version :  V1.0
 * @date :  2022-11-01 10:24
 */
public class DefaultClientConnector extends AbstractClientConnector {

    @Override
    protected ChannelInitializer<?> buildChannelInitializer() {
        return new ChannelInitializer<Channel>() {
            @Override
            protected void initChannel(Channel ch) throws Exception {
//                ChannelPipeline pipeline = ch.pipeline();
//                pipeline.addLast(new IdleStateHandler(0, 0, 60));
            }
        };
    }
}
